# -*- coding:utf-8 -*- 
# @Time : 2021/6/10 11:35
# @Author: sl
# @File : __init__.py.py
from mq.KafkaConsumerStart import KafkaConsumerStart #启动kafka任务
thread = KafkaConsumerStart()
thread.start()